package com.zlx.rulemk.marketing.constant;

/**
 * @Author: zhanglingxing
 * @CreateTime: 2022-07-06
 * @Description: 配置文件，参数名统一管理类
 * @Version: 1.0
 */
public class ConfigNames {
    // kafka地址
    public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers";
    //kafka是否自动提交
    public static final String KAFKA_OFFSET_AUTORESET = "kafka.auto.offset.reset";
    // kafka event topic
    public static final String KAFKA_ACTION_DETAIL_TOPIC = "kafka.action.detail.topic";
    // kafka  rule topic
    public static final String KAFKA_ACTION_RULE_TOPIC = "kafka.action.rule.topic";

    // ck的驱动
    public static final String CK_JDBC_DRIVER = "ck.jdbc.driver";
    // ck的url
    public static final String CK_JDBC_URL = "ck.jdbc.url";
    // CK 的表明
    public static final String CK_JDBC_DETAIL_TABLE = "ck.jdbc.detail.table";

    // hbase zk 的地址
    public static final String HBASE_ZK_QUORUM = "hbase.zookeeper.quorum";
    // hbase 画像表名
    public static final String HBASE_PROFILE_TABLE = "hbase.profile.table";
    // hbase 列簇
    public static final String HBASE_PROFILE_FAMILY = "hbase.profile.family";

    // redis 的地址
    public static final String REDIS_HOST = "redis.host";
    // redis 端口
    public static final String REDIS_PORT = "redis.port";
    // redis 数据TTL时间
    public static final String REDIS_BUFFER_TTL = "reids.buffer.ttl";

    // 系统配置参数
    public static final String  FLINK_POINT_TIME = "flink.point.time";

    // Flink任务的并行度
    public static final String  FLINK_PARALLELISM = "flink.parallelism";


}

